package com.thor.palmmall.util.event;

import java.util.concurrent.Executors;

import com.google.common.eventbus.AsyncEventBus;

public class GlobalEventBus {

  
  /** 异步队列 */
  private final static AsyncEventBus eventBus = new AsyncEventBus(
      Executors.newCachedThreadPool());

  /**
   * 发送同步消息。
   * 
   * @param event
   */
  public static void post(Event event) {
    eventBus.post(event);
  }

  /**
   * 注册同步消息处理器。
   * 
   * @param handler
   */
  public static void register(EventHandler handler) {
    eventBus.register(handler);
  }

  /**
   * 取消同步消息处理器。
   * 
   * @param handler
   */
  public static void unregister(EventHandler handler) {
    eventBus.unregister(handler);
  }
}
